package org.zhadoop.streaming.operator;

import org.zhadoop.streaming.exception.StreamingException;

/**
 *事件发射的接口
 * @author zwd
 *
 */
public interface IEmitter {
	/**
	 * emit 发送数据
	 * @param datas
	 * @throws StreamingException
	 */
	void emit(Object[] datas) throws StreamingException;
}
